package cn.bud.msgbus.consumer.client.provider;

import java.lang.annotation.*;

/**
 * SubscribeProvide
 *
 * @author hxj
 * @version 1.0
 * @description
 * @date 2024-06-24 16:47
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface SubscribeProvide {

    /**
     * 主题
     * @return
     */
    String topic() default "";

    /**
     * 是否异步处理
     * true: 异步处理，无返回值
     * false: 同步处理，有返回值 TODO 暂未实现
     * @return
     */
    boolean async() default true;

}
